package com.alibaba.datax.plugin.reader.kafkareader;

/**
 * @Description: TODO
 * @Author: chenweifeng
 * @Date: 2022年09月05日 上午11:08
 **/
public class Key {

    public final static String TOPIC = "topic";// 主题
    public final static String KAFKA_PARTITIONS = "kafkaPartitions";// 分区数
    public final static String BOOTSTRAP_SERVERS = "bootstrapServers";//
    public final static String GROUP_ID = "groupId";// 消费组
    public final static String COLUMNCOUNT = "columnCount";// 字段数
    public final static String SPLIT = "split";// 分割符
    public final static String CONTAINTS_STR = "filterContaints";// 过滤的字符串 英文逗号隔开
    public final static String CONTAINTS_STR_FLAG = "filterContaintsFlag";// 1 表示包含 0 表示不包含
    public final static String CONDITION_ALL_OR_ONE = "conditionAllOrOne";// 1 全部包含或不包含，0 包含其中一个或者不包含其中一个
    public final static String PARSING_RULES = "parsingRules";//
    public final static String WRITER_ORDER = "writerOrder";//
    public final static String KAFKA_READER_COLUMN_KEY = "kafkaReaderColumnKey";//
    public final static String EXECPTION_PATH = "execptionPath";//
    public final static String ENABLE_AUTO_COMMIT = "enableAutoCommit";// 是否自动提交
    public final static String MAX_POLL_RECORDS = "maxPollRecords";// 最大Poll数

}
